SparkN0de-git - /page/blob.mu

T8b949e#

T8b949e# are made available under the terms of the Eclipse Public License v2.0

T8b949e# and Eclipse Distribution License v1.0 which accompany this distribution.

T8b949e#

T8b949e# The Eclipse Public License is available at

T8b949e# http://www.eclipse.org/legal/epl-v20.html

T8b949e# and the Eclipse Distribution License is available at

T8b949e# http://www.eclipse.org/org/documents/edl-v10.php.

T8b949e#

T8b949e# Contributors:

T8b949e# Roger Light - initial API and implementation

T8b949e# Ian Craggs - MQTT V5 support

T8b949e"""

This is an MQTT client module. MQTT is a lightweight pub/sub messaging

protocol that is easy to implement and suitable for low powered devices.

"""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787base64

Tff7b72import T7ee787collections

Tff7b72import T7ee787errno

Tff7b72import T7ee787hashlib

Tff7b72import T7ee787logging

Tff7b72import T7ee787os

Tff7b72import T7ee787platform

Tff7b72import T7ee787select

Tff7b72import T7ee787socket

Tff7b72import T7ee787string

Tff7b72import T7ee787struct

Tff7b72import T7ee787threading

Tff7b72import T7ee787time

Tff7b72import T7ee787urllibT7ee787.T7ee787parse

Tff7b72import T7ee787urllibT7ee787.T7ee787request

Tff7b72import T7ee787uuid

Tff7b72import T7ee787warnings

Tff7b72from T7ee787typing Tff7b72import Te6edf3TYPE_CHECKINGTb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3CallableTb4b4b4, Te6edf3DictTb4b4b4, Te6edf3IteratorTb4b4b4, Te6edf3ListTb4b4b4, Te6edf3NamedTupleTb4b4b4, Te6edf3SequenceTb4b4b4, Te6edf3TupleTb4b4b4, Te6edf3UnionTb4b4b4, Te6edf3cast

Tff7b72from T7ee787.T7ee787packettypes Tff7b72import Te6edf3PacketTypes

Tff7b72from T7ee787.T7ee787enums Tff7b72import Te6edf3CallbackAPIVersionTb4b4b4, Te6edf3ConnackCodeTb4b4b4, Te6edf3LogLevelTb4b4b4, Te6edf3MessageStateTb4b4b4, Te6edf3MessageTypeTb4b4b4, Te6edf3MQTTErrorCodeTb4b4b4, Te6edf3MQTTProtocolVersionTb4b4b4, Te6edf3PahoClientModeTb4b4b4, Te6edf3_ConnectionState

Tff7b72from T7ee787.T7ee787matcher Tff7b72import Te6edf3MQTTMatcher

Tff7b72from T7ee787.T7ee787properties Tff7b72import Te6edf3Properties

Tff7b72from T7ee787.T7ee787reasoncodes Tff7b72import Te6edf3ReasonCodeTb4b4b4, Te6edf3ReasonCodes

Tff7b72from T7ee787.T7ee787subscribeoptions Tff7b72import Te6edf3SubscribeOptions

Tff7b72tryTb4b4b4:

Tff7b72from T7ee787typing Tff7b72import Te6edf3Literal

Tff7b72except Tf85149ImportErrorTb4b4b4:

Tff7b72from T7ee787typing_extensions Tff7b72import Te6edf3Literal T8b949e# type: ignore

Tff7b72if Te6edf3TYPE_CHECKINGTb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72from T7ee787typing Tff7b72import Te6edf3TypedDict T8b949e# type: ignore

Tff7b72except Tf85149ImportErrorTb4b4b4:

Tff7b72from T7ee787typing_extensions Tff7b72import Te6edf3TypedDict

Tff7b72tryTb4b4b4:

Tff7b72from T7ee787typing Tff7b72import Te6edf3Protocol T8b949e# type: ignore

Tff7b72except Tf85149ImportErrorTb4b4b4:

Tff7b72from T7ee787typing_extensions Tff7b72import Te6edf3Protocol T8b949e# type: ignore

Tff7b72class T56d364_InPacketTb4b4b4(Te6edf3TypedDictTb4b4b4)Tb4b4b4:

Te6edf3commandTb4b4b4: Tffa657int

Te6edf3have_remainingTb4b4b4: Tffa657int

Te6edf3remaining_countTb4b4b4: Tffa657listTb4b4b4[Tffa657intTb4b4b4]

Te6edf3remaining_multTb4b4b4: Tffa657int

Te6edf3remaining_lengthTb4b4b4: Tffa657int

Te6edf3packetTb4b4b4: Tffa657bytearray

Te6edf3to_processTb4b4b4: Tffa657int

Te6edf3posTb4b4b4: Tffa657int

Tff7b72class T56d364_OutPacketTb4b4b4(Te6edf3TypedDictTb4b4b4)Tb4b4b4:

Te6edf3commandTb4b4b4: Tffa657int

Te6edf3midTb4b4b4: Tffa657int

Te6edf3qosTb4b4b4: Tffa657int

Te6edf3posTb4b4b4: Tffa657int

Te6edf3to_processTb4b4b4: Tffa657int

Te6edf3packetTb4b4b4: Tffa657bytes

Te6edf3infoTb4b4b4: Te6edf3MQTTMessageInfo Tff7b72| Tff7b72None

Tff7b72class T56d364SocketLikeTb4b4b4(Te6edf3ProtocolTb4b4b4)Tb4b4b4:

Tff7b72def Td2a8ffrecvTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3buffer_sizeTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72.Tff7b72.Tff7b72.

Tff7b72def Td2a8ffsendTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3bufferTb4b4b4: Tffa657bytesTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Tff7b72.Tff7b72.Tff7b72.

Tff7b72def Td2a8ffcloseTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72.Tff7b72.Tff7b72.

Tff7b72def Td2a8fffilenoTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Tff7b72.Tff7b72.Tff7b72.

Tff7b72def Td2a8ffsetblockingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3flagTb4b4b4: Tffa657boolTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72.Tff7b72.Tff7b72.

Tff7b72tryTb4b4b4:

Tff7b72import T7ee787ssl

Tff7b72except Tf85149ImportErrorTb4b4b4:

Te6edf3ssl Tff7b72= Tff7b72None T8b949e# type: ignore[assignment]

Tff7b72tryTb4b4b4:

Tff7b72import T7ee787socks T8b949e# type: ignore[import-untyped]

Tff7b72except Tf85149ImportErrorTb4b4b4:

Te6edf3socks Tff7b72= Tff7b72None T8b949e# type: ignore[assignment]

Tff7b72tryTb4b4b4:

T8b949e# Use monotonic clock if available

Te6edf3time_func Tff7b72= Te6edf3timeTff7b72.Td2a8ffmonotonic

Tff7b72except Tf85149AttributeErrorTb4b4b4:

Te6edf3time_func Tff7b72= Te6edf3timeTff7b72.Td2a8fftime

Tff7b72tryTb4b4b4:

Tff7b72import T7ee787dnsT7ee787.T7ee787resolver

Te6edf3HAVE_DNS Tff7b72= Tff7b72True

Tff7b72except Tf85149ImportErrorTb4b4b4:

Te6edf3HAVE_DNS Tff7b72= Tff7b72False

Tff7b72if Te6edf3platformTff7b72.Td2a8ffsystemTb4b4b4(Tb4b4b4) Tff7b72== Ta5d6ff'Ta5d6ffWindowsTa5d6ff'Tb4b4b4:

Te6edf3EAGAIN Tff7b72= Te6edf3errnoTff7b72.Td2a8ffWSAEWOULDBLOCK T8b949e# type: ignore[attr-defined]

Tff7b72elseTb4b4b4:

Te6edf3EAGAIN Tff7b72= Te6edf3errnoTff7b72.Td2a8ffEAGAIN

T8b949e# Avoid linter complain. We kept importing it as ReasonCodes (plural) for compatibility

Te6edf3_ Tff7b72= Te6edf3ReasonCodes

T8b949e# Keep copy of enums values for compatibility.

Te6edf3CONNECT Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffCONNECT

Te6edf3CONNACK Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffCONNACK

Te6edf3PUBLISH Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPUBLISH

Te6edf3PUBACK Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPUBACK

Te6edf3PUBREC Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPUBREC

Te6edf3PUBREL Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPUBREL

Te6edf3PUBCOMP Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPUBCOMP

Te6edf3SUBSCRIBE Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffSUBSCRIBE

Te6edf3SUBACK Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffSUBACK

Te6edf3UNSUBSCRIBE Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffUNSUBSCRIBE

Te6edf3UNSUBACK Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffUNSUBACK

Te6edf3PINGREQ Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPINGREQ

Te6edf3PINGRESP Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffPINGRESP

Te6edf3DISCONNECT Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffDISCONNECT

Te6edf3AUTH Tff7b72= Te6edf3MessageTypeTff7b72.Td2a8ffAUTH

T8b949e# Log levels

Te6edf3MQTT_LOG_INFO Tff7b72= Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_INFO

Te6edf3MQTT_LOG_NOTICE Tff7b72= Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_NOTICE

Te6edf3MQTT_LOG_WARNING Tff7b72= Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_WARNING

Te6edf3MQTT_LOG_ERR Tff7b72= Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_ERR

Te6edf3MQTT_LOG_DEBUG Tff7b72= Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_DEBUG

Te6edf3LOGGING_LEVEL Tff7b72= Tb4b4b4{

Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_DEBUGTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffDEBUGTb4b4b4,

Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_INFOTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffINFOTb4b4b4,

Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_NOTICETb4b4b4: Te6edf3loggingTff7b72.Td2a8ffINFOTb4b4b4, T8b949e# This has no direct equivalent level

Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_WARNINGTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffWARNINGTb4b4b4,

Te6edf3LogLevelTff7b72.Td2a8ffMQTT_LOG_ERRTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffERRORTb4b4b4,

Tb4b4b4}

T8b949e# CONNACK codes

Te6edf3CONNACK_ACCEPTED Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_ACCEPTED

Te6edf3CONNACK_REFUSED_PROTOCOL_VERSION Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_PROTOCOL_VERSION

Te6edf3CONNACK_REFUSED_IDENTIFIER_REJECTED Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_IDENTIFIER_REJECTED

Te6edf3CONNACK_REFUSED_SERVER_UNAVAILABLE Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_SERVER_UNAVAILABLE

Te6edf3CONNACK_REFUSED_BAD_USERNAME_PASSWORD Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_BAD_USERNAME_PASSWORD

Te6edf3CONNACK_REFUSED_NOT_AUTHORIZED Tff7b72= Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_NOT_AUTHORIZED

T8b949e# Message state

Te6edf3mqtt_ms_invalid Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_INVALID

Te6edf3mqtt_ms_publish Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_PUBLISH

Te6edf3mqtt_ms_wait_for_puback Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_WAIT_FOR_PUBACK

Te6edf3mqtt_ms_wait_for_pubrec Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_WAIT_FOR_PUBREC

Te6edf3mqtt_ms_resend_pubrel Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_RESEND_PUBREL

Te6edf3mqtt_ms_wait_for_pubrel Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_WAIT_FOR_PUBREL

Te6edf3mqtt_ms_resend_pubcomp Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_RESEND_PUBCOMP

Te6edf3mqtt_ms_wait_for_pubcomp Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_WAIT_FOR_PUBCOMP

Te6edf3mqtt_ms_send_pubrec Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_SEND_PUBREC

Te6edf3mqtt_ms_queued Tff7b72= Te6edf3MessageStateTff7b72.Td2a8ffMQTT_MS_QUEUED

Te6edf3MQTT_ERR_AGAIN Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_AGAIN

Te6edf3MQTT_ERR_SUCCESS Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_SUCCESS

Te6edf3MQTT_ERR_NOMEM Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_NOMEM

Te6edf3MQTT_ERR_PROTOCOL Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_PROTOCOL

Te6edf3MQTT_ERR_INVAL Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_INVAL

Te6edf3MQTT_ERR_NO_CONN Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_NO_CONN

Te6edf3MQTT_ERR_CONN_REFUSED Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_CONN_REFUSED

Te6edf3MQTT_ERR_NOT_FOUND Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_NOT_FOUND

Te6edf3MQTT_ERR_CONN_LOST Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_CONN_LOST

Te6edf3MQTT_ERR_TLS Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_TLS

Te6edf3MQTT_ERR_PAYLOAD_SIZE Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_PAYLOAD_SIZE

Te6edf3MQTT_ERR_NOT_SUPPORTED Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_NOT_SUPPORTED

Te6edf3MQTT_ERR_AUTH Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_AUTH

Te6edf3MQTT_ERR_ACL_DENIED Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_ACL_DENIED

Te6edf3MQTT_ERR_UNKNOWN Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_UNKNOWN

Te6edf3MQTT_ERR_ERRNO Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_ERRNO

Te6edf3MQTT_ERR_QUEUE_SIZE Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_QUEUE_SIZE

Te6edf3MQTT_ERR_KEEPALIVE Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_KEEPALIVE

Te6edf3MQTTv31 Tff7b72= Te6edf3MQTTProtocolVersionTff7b72.Td2a8ffMQTTv31

Te6edf3MQTTv311 Tff7b72= Te6edf3MQTTProtocolVersionTff7b72.Td2a8ffMQTTv311

Te6edf3MQTTv5 Tff7b72= Te6edf3MQTTProtocolVersionTff7b72.Td2a8ffMQTTv5

Te6edf3MQTT_CLIENT Tff7b72= Te6edf3PahoClientModeTff7b72.Td2a8ffMQTT_CLIENT

Te6edf3MQTT_BRIDGE Tff7b72= Te6edf3PahoClientModeTff7b72.Td2a8ffMQTT_BRIDGE

T8b949e# For MQTT V5, use the clean start flag only on the first successful connect

Te6edf3MQTT_CLEAN_START_FIRST_ONLYTb4b4b4: Te6edf3CleanStartOption Tff7b72= T79c0ff3

Te6edf3sockpair_data Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff0Ta5d6ff"

T8b949e# Payload support all those type and will be converted to bytes:

T8b949e# * str are utf8 encoded

T8b949e# * int/float are converted to string and utf8 encoded (e.g. 1 is converted to b"1")

T8b949e# * None is converted to a zero-length payload (i.e. b"")

Te6edf3PayloadType Tff7b72= Te6edf3UnionTb4b4b4[Tffa657strTb4b4b4, Tffa657bytesTb4b4b4, Tffa657bytearrayTb4b4b4, Tffa657intTb4b4b4, Tffa657floatTb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3HTTPHeader Tff7b72= Te6edf3DictTb4b4b4[Tffa657strTb4b4b4, Tffa657strTb4b4b4]

Te6edf3WebSocketHeaders Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallableTb4b4b4[Tb4b4b4[Te6edf3HTTPHeaderTb4b4b4]Tb4b4b4, Te6edf3HTTPHeaderTb4b4b4]Tb4b4b4, Te6edf3HTTPHeaderTb4b4b4]

Te6edf3CleanStartOption Tff7b72= Te6edf3UnionTb4b4b4[Tffa657boolTb4b4b4, Te6edf3LiteralTb4b4b4[T79c0ff3Tb4b4b4]Tb4b4b4]

Tff7b72class T56d364ConnectFlagsTb4b4b4(Te6edf3NamedTupleTb4b4b4)Tb4b4b4:

T8b949e"""Contains additional information passed to `on_connect` callback"""

Te6edf3session_presentTb4b4b4: Tffa657bool

T8b949e"""

this flag is useful for clients that are

using clean session set to False only (MQTTv3) or clean_start = False (MQTTv5).

In that case, if client that reconnects to a broker that it has previously

connected to, this flag indicates whether the broker still has the

session information for the client. If true, the session still exists.

"""

Tff7b72class T56d364DisconnectFlagsTb4b4b4(Te6edf3NamedTupleTb4b4b4)Tb4b4b4:

T8b949e"""Contains additional information passed to `on_disconnect` callback"""

Te6edf3is_disconnect_packet_from_serverTb4b4b4: Tffa657bool

T8b949e"""

tells whether this on_disconnect call is the result

of receiving an DISCONNECT packet from the broker or if the on_disconnect is only

generated by the client library.

When true, the reason code is generated by the broker.

"""

Te6edf3CallbackOnConnect_v1_mqtt3 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3DictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4, Te6edf3MQTTErrorCodeTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnConnect_v1_mqtt5 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3DictTb4b4b4[Tffa657strTb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4, Te6edf3ReasonCodeTb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnConnect_v1 Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnConnect_v1_mqtt5Tb4b4b4, Te6edf3CallbackOnConnect_v1_mqtt3Tb4b4b4]

Te6edf3CallbackOnConnect_v2 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3ConnectFlagsTb4b4b4, Te6edf3ReasonCodeTb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnConnect Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnConnect_v1Tb4b4b4, Te6edf3CallbackOnConnect_v2Tb4b4b4]

Te6edf3CallbackOnConnectFail Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnDisconnect_v1_mqtt3 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3MQTTErrorCodeTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnDisconnect_v1_mqtt5 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3ReasonCodeTb4b4b4, Tffa657intTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnDisconnect_v1 Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnDisconnect_v1_mqtt3Tb4b4b4, Te6edf3CallbackOnDisconnect_v1_mqtt5Tb4b4b4]

Te6edf3CallbackOnDisconnect_v2 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Te6edf3DisconnectFlagsTb4b4b4, Te6edf3ReasonCodeTb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnDisconnect Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnDisconnect_v1Tb4b4b4, Te6edf3CallbackOnDisconnect_v2Tb4b4b4]

Te6edf3CallbackOnLog Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Tffa657strTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnMessage Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Ta5d6ff"Ta5d6ffMQTTMessageTa5d6ff"Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnPreConnect Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnPublish_v1 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnPublish_v2 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3ReasonCodeTb4b4b4, Te6edf3PropertiesTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnPublish Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnPublish_v1Tb4b4b4, Te6edf3CallbackOnPublish_v2Tb4b4b4]

Te6edf3CallbackOnSocket Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Ta5d6ff"Ta5d6ffSocketLikeTa5d6ff"Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnSubscribe_v1_mqtt3 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3TupleTb4b4b4[Tffa657intTb4b4b4, Tff7b72.Tff7b72.Tff7b72.Tb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnSubscribe_v1_mqtt5 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3ListTb4b4b4[Te6edf3ReasonCodeTb4b4b4]Tb4b4b4, Te6edf3PropertiesTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnSubscribe_v1 Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnSubscribe_v1_mqtt3Tb4b4b4, Te6edf3CallbackOnSubscribe_v1_mqtt5Tb4b4b4]

Te6edf3CallbackOnSubscribe_v2 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3ListTb4b4b4[Te6edf3ReasonCodeTb4b4b4]Tb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnSubscribe Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnSubscribe_v1Tb4b4b4, Te6edf3CallbackOnSubscribe_v2Tb4b4b4]

Te6edf3CallbackOnUnsubscribe_v1_mqtt3 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnUnsubscribe_v1_mqtt5 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3PropertiesTb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3ReasonCodeTb4b4b4, Te6edf3ListTb4b4b4[Te6edf3ReasonCodeTb4b4b4]Tb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnUnsubscribe_v1 Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnUnsubscribe_v1_mqtt3Tb4b4b4, Te6edf3CallbackOnUnsubscribe_v1_mqtt5Tb4b4b4]

Te6edf3CallbackOnUnsubscribe_v2 Tff7b72= Te6edf3CallableTb4b4b4[Tb4b4b4[Ta5d6ff"Ta5d6ffClientTa5d6ff"Tb4b4b4, Te6edf3AnyTb4b4b4, Tffa657intTb4b4b4, Te6edf3ListTb4b4b4[Te6edf3ReasonCodeTb4b4b4]Tb4b4b4, Te6edf3UnionTb4b4b4[Te6edf3PropertiesTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4]

Te6edf3CallbackOnUnsubscribe Tff7b72= Te6edf3UnionTb4b4b4[Te6edf3CallbackOnUnsubscribe_v1Tb4b4b4, Te6edf3CallbackOnUnsubscribe_v2Tb4b4b4]

T8b949e# This is needed for typing because class Client redefined the name "socket"

Te6edf3_socket Tff7b72= Te6edf3socket

Tff7b72class T56d364WebsocketConnectionErrorTb4b4b4(Tf85149ConnectionErrorTb4b4b4)Tb4b4b4:

T8b949e""" WebsocketConnectionError is a subclass of ConnectionError.

It's raised when unable to perform the Websocket handshake.

"""

Tff7b72pass

Tff7b72def Td2a8fferror_stringTb4b4b4(Te6edf3mqtt_errnoTb4b4b4: Te6edf3MQTTErrorCode Tff7b72| Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

T8b949e"""Return the error string associated with an mqtt error number."""

Tff7b72if Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_SUCCESSTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffNo error.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_NOMEMTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffOut of memory.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_PROTOCOLTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffA network protocol error occurred when communicating with the broker.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_INVALTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffInvalid function arguments provided.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_NO_CONNTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffThe client is not currently connected.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_CONN_REFUSEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffThe connection was refused.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_NOT_FOUNDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffMessage not found (internal error).Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_CONN_LOSTTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffThe connection was lost.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_TLSTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffA TLS error occurred.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_PAYLOAD_SIZETb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffPayload too large.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_NOT_SUPPORTEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffThis feature is not supported.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_AUTHTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffAuthorisation failed.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_ACL_DENIEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffAccess denied by ACL.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_UNKNOWNTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffUnknown error.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_ERRNOTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffError defined by errno.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_QUEUE_SIZETb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffMessage queue full.Ta5d6ff"

Tff7b72elif Te6edf3mqtt_errno Tff7b72== Te6edf3MQTT_ERR_KEEPALIVETb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffClient or broker did not communicate in the keepalive interval.Ta5d6ff"

Tff7b72elseTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffUnknown error.Ta5d6ff"

Tff7b72def Td2a8ffconnack_stringTb4b4b4(Te6edf3connack_codeTb4b4b4: Tffa657intTff7b72|Te6edf3ReasonCodeTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

T8b949e"""Return the string associated with a CONNACK result or CONNACK reason code."""

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3connack_codeTb4b4b4, Te6edf3ReasonCodeTb4b4b4)Tb4b4b4:

Tff7b72return Tffa657strTb4b4b4(Te6edf3connack_codeTb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3CONNACK_ACCEPTEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Accepted.Ta5d6ff"

Tff7b72elif Te6edf3connack_code Tff7b72== Te6edf3CONNACK_REFUSED_PROTOCOL_VERSIONTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: unacceptable protocol version.Ta5d6ff"

Tff7b72elif Te6edf3connack_code Tff7b72== Te6edf3CONNACK_REFUSED_IDENTIFIER_REJECTEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: identifier rejected.Ta5d6ff"

Tff7b72elif Te6edf3connack_code Tff7b72== Te6edf3CONNACK_REFUSED_SERVER_UNAVAILABLETb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: broker unavailable.Ta5d6ff"

Tff7b72elif Te6edf3connack_code Tff7b72== Te6edf3CONNACK_REFUSED_BAD_USERNAME_PASSWORDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: bad user name or password.Ta5d6ff"

Tff7b72elif Te6edf3connack_code Tff7b72== Te6edf3CONNACK_REFUSED_NOT_AUTHORIZEDTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: not authorised.Ta5d6ff"

Tff7b72elseTb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffConnection Refused: unknown reason.Ta5d6ff"

Tff7b72def Td2a8ffconvert_connack_rc_to_reason_codeTb4b4b4(Te6edf3connack_codeTb4b4b4: Te6edf3ConnackCodeTb4b4b4) Tff7b72-Tff7b72> Te6edf3ReasonCodeTb4b4b4:

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_ACCEPTEDTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffSuccessTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_PROTOCOL_VERSIONTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffUnsupported protocol versionTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_IDENTIFIER_REJECTEDTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffClient identifier not validTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_SERVER_UNAVAILABLETb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffServer unavailableTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_BAD_USERNAME_PASSWORDTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffBad user name or passwordTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3connack_code Tff7b72== Te6edf3ConnackCodeTff7b72.Td2a8ffCONNACK_REFUSED_NOT_AUTHORIZEDTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffNot authorizedTa5d6ff"Tb4b4b4)

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffCONNACKTb4b4b4, Ta5d6ff"Ta5d6ffUnspecified errorTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffconvert_disconnect_error_code_to_reason_codeTb4b4b4(Te6edf3rcTb4b4b4: Te6edf3MQTTErrorCodeTb4b4b4) Tff7b72-Tff7b72> Te6edf3ReasonCodeTb4b4b4:

Tff7b72if Te6edf3rc Tff7b72== Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_SUCCESSTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffDISCONNECTTb4b4b4, Ta5d6ff"Ta5d6ffSuccessTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3rc Tff7b72== Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_KEEPALIVETb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffDISCONNECTTb4b4b4, Ta5d6ff"Ta5d6ffKeep alive timeoutTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3rc Tff7b72== Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_CONN_LOSTTb4b4b4:

Tff7b72return Te6edf3ReasonCodeTb4b4b4(Te6edf3PacketTypesTff7b72.Td2a8ffDISCONNECTTb4b4b4, Ta5d6ff"Ta5d6ffUnspecified errorTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ff_base62Tb4b4b4(

Te6edf3numTb4b4b4: Tffa657intTb4b4b4,

Te6edf3baseTb4b4b4: Tffa657str Tff7b72= Te6edf3stringTff7b72.Td2a8ffdigits Tff7b72+ Te6edf3stringTff7b72.Td2a8ffascii_lettersTb4b4b4,

Te6edf3paddingTb4b4b4: Tffa657int Tff7b72= T79c0ff1Tb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

T8b949e"""Convert a number to base-62 representation."""

Tff7b72if Te6edf3num Tff7b72< T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffNumber must be positive or zeroTa5d6ff"Tb4b4b4)

Te6edf3digits Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72while Te6edf3numTb4b4b4:

Te6edf3numTb4b4b4, Te6edf3rest Tff7b72= Tffa657divmodTb4b4b4(Te6edf3numTb4b4b4, T79c0ff62Tb4b4b4)

Te6edf3digitsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3baseTb4b4b4[Te6edf3restTb4b4b4]Tb4b4b4)

Te6edf3digitsTff7b72.Td2a8ffextendTb4b4b4(Te6edf3baseTb4b4b4[T79c0ff0Tb4b4b4] Tff7b72for Te6edf3_ Tff7b72in Tffa657rangeTb4b4b4(Tffa657lenTb4b4b4(Te6edf3digitsTb4b4b4)Tb4b4b4, Te6edf3paddingTb4b4b4)Tb4b4b4)

Tff7b72return Ta5d6ff'Ta5d6ff'Tff7b72.Td2a8ffjoinTb4b4b4(Tffa657reversedTb4b4b4(Te6edf3digitsTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8fftopic_matches_subTb4b4b4(Te6edf3subTb4b4b4: Tffa657strTb4b4b4, Te6edf3topicTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

T8b949e"""Check whether a topic matches a subscription.

For example:

* Topic "foo/bar" would match the subscription "foo/#" or "+/bar"

* Topic "non/matching" would not match the subscription "non/+/+"

"""

Te6edf3matcher Tff7b72= Te6edf3MQTTMatcherTb4b4b4(Tb4b4b4)

Te6edf3matcherTb4b4b4[Te6edf3subTb4b4b4] Tff7b72= Tff7b72True

Tff7b72tryTb4b4b4:

Tffa657nextTb4b4b4(Te6edf3matcherTff7b72.Td2a8ffiter_matchTb4b4b4(Te6edf3topicTb4b4b4)Tb4b4b4)

Tff7b72return Tff7b72True

Tff7b72except Tf85149StopIterationTb4b4b4:

Tff7b72return Tff7b72False

Tff7b72def Td2a8ff_socketpair_compatTb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657tupleTb4b4b4[Te6edf3socketTff7b72.Td2a8ffsocketTb4b4b4, Te6edf3socketTff7b72.Td2a8ffsocketTb4b4b4]Tb4b4b4:

T8b949e"""TCP/IP socketpair including Windows support"""

Te6edf3listensock Tff7b72= Te6edf3socketTff7b72.Td2a8ffsocketTb4b4b4(

Te6edf3socketTff7b72.Td2a8ffAF_INETTb4b4b4, Te6edf3socketTff7b72.Td2a8ffSOCK_STREAMTb4b4b4, Te6edf3socketTff7b72.Td2a8ffIPPROTO_IPTb4b4b4)

Te6edf3listensockTff7b72.Td2a8ffsetsockoptTb4b4b4(Te6edf3socketTff7b72.Td2a8ffSOL_SOCKETTb4b4b4, Te6edf3socketTff7b72.Td2a8ffSO_REUSEADDRTb4b4b4, T79c0ff1Tb4b4b4)

Te6edf3listensockTff7b72.Td2a8ffbindTb4b4b4(Tb4b4b4(Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, T79c0ff0Tb4b4b4)Tb4b4b4)

Te6edf3listensockTff7b72.Td2a8fflistenTb4b4b4(T79c0ff1Tb4b4b4)

Te6edf3ifaceTb4b4b4, Te6edf3port Tff7b72= Te6edf3listensockTff7b72.Td2a8ffgetsocknameTb4b4b4(Tb4b4b4)

Te6edf3sock1 Tff7b72= Te6edf3socketTff7b72.Td2a8ffsocketTb4b4b4(

Te6edf3socketTff7b72.Td2a8ffAF_INETTb4b4b4, Te6edf3socketTff7b72.Td2a8ffSOCK_STREAMTb4b4b4, Te6edf3socketTff7b72.Td2a8ffIPPROTO_IPTb4b4b4)

Te6edf3sock1Tff7b72.Td2a8ffsetblockingTb4b4b4(Tff7b72FalseTb4b4b4)

Tff7b72tryTb4b4b4:

Te6edf3sock1Tff7b72.Td2a8ffconnectTb4b4b4(Tb4b4b4(Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Te6edf3portTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149BlockingIOErrorTb4b4b4:

Tff7b72pass

Te6edf3sock2Tb4b4b4, Te6edf3address Tff7b72= Te6edf3listensockTff7b72.Td2a8ffacceptTb4b4b4(Tb4b4b4)

Te6edf3sock2Tff7b72.Td2a8ffsetblockingTb4b4b4(Tff7b72FalseTb4b4b4)

Te6edf3listensockTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72return Tb4b4b4(Te6edf3sock1Tb4b4b4, Te6edf3sock2Tb4b4b4)

Tff7b72def Td2a8ff_force_bytesTb4b4b4(Te6edf3sTb4b4b4: Tffa657str Tff7b72| Tffa657bytesTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3sTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3sTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tff7b72return Te6edf3s

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3payloadTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3payloadTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3payloadTb4b4b4, Tb4b4b4(Tffa657intTb4b4b4, Tffa657floatTb4b4b4)Tb4b4b4)Tb4b4b4:

Tff7b72return Tffa657strTb4b4b4(Te6edf3payloadTb4b4b4)Tff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffasciiTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3payload Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3payloadTb4b4b4, Tb4b4b4(Tffa657bytesTb4b4b4, Tffa657bytearrayTb4b4b4)Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149TypeErrorTb4b4b4(

Ta5d6ff"Ta5d6ffpayload must be a string, bytearray, int, float or None.Ta5d6ff"

Tb4b4b4)

Tff7b72return Te6edf3payload

Tff7b72class T56d364MQTTMessageInfoTb4b4b4:

Tff7b72__slots__ Tff7b72= Ta5d6ff'Ta5d6ffmidTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ff_publishedTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ff_conditionTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffrcTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ff_iterposTa5d6ff'

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3midTb4b4b4: Tffa657intTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffmid Tff7b72= Te6edf3mid

T8b949e""" The message Id (int)"""

Tff7b72selfTff7b72.Td2a8ff_published Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_condition Tff7b72= Te6edf3threadingTff7b72.Td2a8ffConditionTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffrcTb4b4b4: Te6edf3MQTTErrorCode Tff7b72= Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_SUCCESS

T8b949e""" The `MQTTErrorCode` that give status for this message.

This value could change until the message `is_published`"""

Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72= T79c0ff0

Tff7b72def Tff7b72__str__Tb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

Tff7b72return Tffa657strTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffrcTb4b4b4, Tff7b72selfTff7b72.Td2a8ffmidTb4b4b4)Tb4b4b4)

Tff7b72def Tff7b72__iter__Tb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3IteratorTb4b4b4[Te6edf3MQTTErrorCode Tff7b72| Tffa657intTb4b4b4]Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72= T79c0ff0

Tff7b72return Tff7b72self

Tff7b72def Tff7b72__next__Tb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTErrorCode Tff7b72| Tffa657intTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffnextTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffnextTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTErrorCode Tff7b72| Tffa657intTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72= T79c0ff1

Tff7b72return Tff7b72selfTff7b72.Td2a8ffrc

Tff7b72elif Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72== T79c0ff1Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_iterpos Tff7b72= T79c0ff2

Tff7b72return Tff7b72selfTff7b72.Td2a8ffmid

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149StopIteration

Tff7b72def Tff7b72__getitem__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3indexTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTErrorCode Tff7b72| Tffa657intTb4b4b4:

Tff7b72if Te6edf3index Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffrc

Tff7b72elif Te6edf3index Tff7b72== T79c0ff1Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffmid

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149IndexErrorTb4b4b4(Ta5d6ff"Ta5d6ffindex out of rangeTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ff_set_as_publishedTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72with Tff7b72selfTff7b72.Td2a8ff_conditionTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_published Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ff_conditionTff7b72.Td2a8ffnotifyTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffwait_for_publishTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3timeoutTb4b4b4: Tffa657float Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffrc Tff7b72== Te6edf3MQTT_ERR_QUEUE_SIZETb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffMessage is not queued due to ERR_QUEUE_SIZETa5d6ff'Tb4b4b4)

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffrc Tff7b72== Te6edf3MQTT_ERR_AGAINTb4b4b4:

Tff7b72pass

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffrc Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6fffTa5d6ff'Ta5d6ffMessage publish failed: Tffd700{Te6edf3error_stringTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrcTb4b4b4)Tffd700}Ta5d6ff'Tb4b4b4)

Te6edf3timeout_time Tff7b72= Tff7b72None Tff7b72if Te6edf3timeout Tff7b72is Tff7b72None Tff7b72else Te6edf3time_funcTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3timeout

Te6edf3timeout_tenth Tff7b72= Tff7b72None Tff7b72if Te6edf3timeout Tff7b72is Tff7b72None Tff7b72else Te6edf3timeout Tff7b72/ T79c0ff10.

Tff7b72def Td2a8fftimed_outTb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

Tff7b72return Tff7b72False Tff7b72if Te6edf3timeout_time Tff7b72is Tff7b72None Tff7b72else Te6edf3time_funcTb4b4b4(Tb4b4b4) Tff7b72> Te6edf3timeout_time

Tff7b72with Tff7b72selfTff7b72.Td2a8ff_conditionTb4b4b4:

Tff7b72while Tff7b72not Tff7b72selfTff7b72.Td2a8ff_published Tff7b72and Tff7b72not Te6edf3timed_outTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_conditionTff7b72.Td2a8ffwaitTb4b4b4(Te6edf3timeout_tenthTb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffrc Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6fffTa5d6ff'Ta5d6ffMessage publish failed: Tffd700{Te6edf3error_stringTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrcTb4b4b4)Tffd700}Ta5d6ff'Tb4b4b4)

Tff7b72def Td2a8ffis_publishedTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

T8b949e"""Returns True if the message associated with this object has been

published, else returns False.

To wait for this to become true, look at `wait_for_publish`.

"""

Tff7b72if Tff7b72selfTff7b72.Td2a8ffrc Tff7b72== Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_QUEUE_SIZETb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffMessage is not queued due to ERR_QUEUE_SIZETa5d6ff'Tb4b4b4)

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffrc Tff7b72== Te6edf3MQTTErrorCodeTff7b72.Td2a8ffMQTT_ERR_AGAINTb4b4b4:

Tff7b72pass

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffrc Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6fffTa5d6ff'Ta5d6ffMessage publish failed: Tffd700{Te6edf3error_stringTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrcTb4b4b4)Tffd700}Ta5d6ff'Tb4b4b4)

Tff7b72with Tff7b72selfTff7b72.Td2a8ff_conditionTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_published

Tff7b72class T56d364MQTTMessageTb4b4b4:

Tff7b72__slots__ Tff7b72= Ta5d6ff'Ta5d6fftimestampTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffstateTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffdupTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffmidTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ff_topicTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffpayloadTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffqosTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffretainTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffinfoTa5d6ff'Tb4b4b4, Ta5d6ff'Ta5d6ffpropertiesTa5d6ff'

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3midTb4b4b4: Tffa657int Tff7b72= T79c0ff0Tb4b4b4, Te6edf3topicTb4b4b4: Tffa657bytes Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8fftimestamp Tff7b72= T79c0ff0.0

Tff7b72selfTff7b72.Td2a8ffstate Tff7b72= Te6edf3mqtt_ms_invalid

Tff7b72selfTff7b72.Td2a8ffdup Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffmid Tff7b72= Te6edf3mid

T8b949e""" The message id (int)."""

Tff7b72selfTff7b72.Td2a8ff_topic Tff7b72= Te6edf3topic

Tff7b72selfTff7b72.Td2a8ffpayload Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

T8b949e"""the message payload (bytes)"""

Tff7b72selfTff7b72.Td2a8ffqos Tff7b72= T79c0ff0

T8b949e""" The message Quality of Service (0, 1 or 2)."""

Tff7b72selfTff7b72.Td2a8ffretain Tff7b72= Tff7b72False

T8b949e""" If true, the message is a retained message and not fresh."""

Tff7b72selfTff7b72.Td2a8ffinfo Tff7b72= Te6edf3MQTTMessageInfoTb4b4b4(Te6edf3midTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72None

T8b949e""" In MQTT v5.0, the properties associated with the message. (`Properties`)"""

Tff7b72def Tff7b72__eq__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3otherTb4b4b4: Tffa657objectTb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

T8b949e"""Override the default Equals behavior"""

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3otherTb4b4b4, Tff7b72selfTff7b72.Td2a8ff__class__Tb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffmid Tff7b72== Te6edf3otherTff7b72.Td2a8ffmid

Tff7b72return Tff7b72False

Tff7b72def Tff7b72__ne__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3otherTb4b4b4: Tffa657objectTb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

T8b949e"""Define a non-equality test"""

Tff7b72return Tff7b72not Tff7b72selfTff7b72.Td2a8ff__eq__Tb4b4b4(Te6edf3otherTb4b4b4)

Tf0883e@property

Tff7b72def Td2a8fftopicTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

T8b949e"""topic that the message was published on.

This property is read-only.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_topicTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff'Ta5d6ffutf-8Ta5d6ff'Tb4b4b4)

Tf0883e@topicTff7b72.Td2a8ffsetter

Tff7b72def Td2a8fftopicTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657bytesTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_topic Tff7b72= Te6edf3value

Tff7b72class T56d364ClientTb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3callback_api_versionTb4b4b4: Te6edf3CallbackAPIVersion Tff7b72= Te6edf3CallbackAPIVersionTff7b72.Td2a8ffVERSION1Tb4b4b4,

Te6edf3client_idTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,

Te6edf3clean_sessionTb4b4b4: Tffa657bool Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3userdataTb4b4b4: Te6edf3Any Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3protocolTb4b4b4: Te6edf3MQTTProtocolVersion Tff7b72= Te6edf3MQTTv311Tb4b4b4,

Te6edf3transportTb4b4b4: Te6edf3LiteralTb4b4b4[Ta5d6ff"Ta5d6fftcpTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwebsocketsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffunixTa5d6ff"Tb4b4b4] Tff7b72= Ta5d6ff"Ta5d6fftcpTa5d6ff"Tb4b4b4,

Te6edf3reconnect_on_failureTb4b4b4: Tffa657bool Tff7b72= Tff7b72TrueTb4b4b4,

Te6edf3manual_ackTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Te6edf3transport Tff7b72= Te6edf3transportTff7b72.Td2a8fflowerTb4b4b4(Tb4b4b4) T8b949e# type: ignore

Tff7b72if Te6edf3transport Tff7b72== Ta5d6ff"Ta5d6ffunixTa5d6ff" Tff7b72and Tff7b72not Tffa657hasattrTb4b4b4(Te6edf3socketTb4b4b4, Ta5d6ff"Ta5d6ffAF_UNIXTa5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ff"Ta5d6ffunixTa5d6ff"Ta5d6ff transport not supportedTa5d6ff'Tb4b4b4)

Tff7b72elif Te6edf3transport Tff7b72not Tff7b72in Tb4b4b4(Ta5d6ff"Ta5d6ffwebsocketsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6fftcpTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffunixTa5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6fffTa5d6ff'Ta5d6fftransport must be Ta5d6ff"Ta5d6ffwebsocketsTa5d6ff"Ta5d6ff, Ta5d6ff"Ta5d6fftcpTa5d6ff"Ta5d6ff or Ta5d6ff"Ta5d6ffunixTa5d6ff"Ta5d6ff, not Tffd700{Te6edf3transportTffd700}Ta5d6ff'Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_manual_ack Tff7b72= Te6edf3manual_ack

Tff7b72selfTff7b72.Td2a8ff_transport Tff7b72= Te6edf3transport

Tff7b72selfTff7b72.Td2a8ff_protocol Tff7b72= Te6edf3protocol

Tff7b72selfTff7b72.Td2a8ff_userdata Tff7b72= Te6edf3userdata

Tff7b72selfTff7b72.Td2a8ff_sockTb4b4b4: Te6edf3SocketLike Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_sockpairRTb4b4b4: Te6edf3socketTff7b72.Td2a8ffsocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_sockpairWTb4b4b4: Te6edf3socketTff7b72.Td2a8ffsocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_keepalive Tff7b72= T79c0ff60

Tff7b72selfTff7b72.Td2a8ff_connect_timeout Tff7b72= T79c0ff5.0

Tff7b72selfTff7b72.Td2a8ff_client_mode Tff7b72= Te6edf3MQTT_CLIENT

Tff7b72selfTff7b72.Td2a8ff_callback_api_version Tff7b72= Te6edf3callback_api_version

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_callback_api_version Tff7b72== Te6edf3CallbackAPIVersionTff7b72.Td2a8ffVERSION1Tb4b4b4:

Te6edf3warningsTff7b72.Td2a8ffwarnTb4b4b4(

Ta5d6ff"Ta5d6ffCallback API version 1 is deprecated, update to latest versionTa5d6ff"Tb4b4b4,

Te6edf3categoryTff7b72=Tf85149DeprecationWarningTb4b4b4,

Te6edf3stacklevelTff7b72=T79c0ff2Tb4b4b4,

Tb4b4b4)

Tff7b72if Tffa657isinstanceTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_callback_api_versionTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:

T8b949e# Help user to migrate, it probably provided a client id

T8b949e# as first arguments

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff"Ta5d6ffUnsupported callback API version: version 2.0 added a callback_api_version, see docs/migrations.rst for detailsTa5d6ff"

Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_callback_api_version Tff7b72not Tff7b72in Te6edf3CallbackAPIVersionTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffUnsupported callback API versionTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_clean_startTb4b4b4: Tffa657int Tff7b72= Te6edf3MQTT_CLEAN_START_FIRST_ONLY

Tff7b72if Te6edf3protocol Tff7b72== Te6edf3MQTTv5Tb4b4b4:

Tff7b72if Te6edf3clean_session Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffClean session is not used for MQTT 5.0Ta5d6ff'Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72if Te6edf3clean_session Tff7b72is Tff7b72NoneTb4b4b4:

Te6edf3clean_session Tff7b72= Tff7b72True

Tff7b72if Tff7b72not Te6edf3clean_session Tff7b72and Tb4b4b4(Te6edf3client_id Tff7b72== Ta5d6ff"Ta5d6ff" Tff7b72or Te6edf3client_id Tff7b72is Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff'Ta5d6ffA client id must be provided if clean session is False.Ta5d6ff'Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_clean_session Tff7b72= Te6edf3clean_session

T8b949e# [MQTT-3.1.3-4] Client Id must be UTF-8 encoded string.

Tff7b72if Te6edf3client_id Tff7b72== Ta5d6ff"Ta5d6ff" Tff7b72or Te6edf3client_id Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72if Te6edf3protocol Tff7b72== Te6edf3MQTTv31Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_client_id Tff7b72= Te6edf3_base62Tb4b4b4(Te6edf3uuidTff7b72.Td2a8ffuuid4Tb4b4b4(Tb4b4b4)Tff7b72.Td2a8ffintTb4b4b4, Te6edf3paddingTff7b72=T79c0ff22Tb4b4b4)Tff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf8Ta5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_client_id Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_client_id Tff7b72= Te6edf3_force_bytesTb4b4b4(Te6edf3client_idTb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_usernameTb4b4b4: Tffa657bytes Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_passwordTb4b4b4: Tffa657bytes Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_in_packetTb4b4b4: Te6edf3_InPacket Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6ffcommandTa5d6ff"Tb4b4b4: T79c0ff0Tb4b4b4,

Ta5d6ff"Ta5d6ffhave_remainingTa5d6ff"Tb4b4b4: T79c0ff0Tb4b4b4,

Ta5d6ff"Ta5d6ffremaining_countTa5d6ff"Tb4b4b4: Tb4b4b4[Tb4b4b4]Tb4b4b4,

Ta5d6ff"Ta5d6ffremaining_multTa5d6ff"Tb4b4b4: T79c0ff1Tb4b4b4,

Ta5d6ff"Ta5d6ffremaining_lengthTa5d6ff"Tb4b4b4: T79c0ff0Tb4b4b4,

Ta5d6ff"Ta5d6ffpacketTa5d6ff"Tb4b4b4: Tffa657bytearrayTb4b4b4(Ta5d6ffbTa5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffto_processTa5d6ff"Tb4b4b4: T79c0ff0Tb4b4b4,

Ta5d6ff"Ta5d6ffposTa5d6ff"Tb4b4b4: T79c0ff0Tb4b4b4,

Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ff_out_packetTb4b4b4: Te6edf3collectionsTff7b72.Td2a8ffdequeTb4b4b4[Te6edf3_OutPacketTb4b4b4] Tff7b72= Te6edf3collectionsTff7b72.Td2a8ffdequeTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_last_msg_in Tff7b72= Te6edf3time_funcTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_last_msg_out Tff7b72= Te6edf3time_funcTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_reconnect_min_delay Tff7b72= T79c0ff1

Tff7b72selfTff7b72.Td2a8ff_reconnect_max_delay Tff7b72= T79c0ff120

Tff7b72selfTff7b72.Td2a8ff_reconnect_delayTb4b4b4: Tffa657int Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_reconnect_on_failure Tff7b72= Te6edf3reconnect_on_failure

Tff7b72selfTff7b72.Td2a8ff_ping_t Tff7b72= T79c0ff0.0

Tff7b72selfTff7b72.Td2a8ff_last_mid Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ff_state Tff7b72= Te6edf3_ConnectionStateTff7b72.Td2a8ffMQTT_CS_NEW

Tff7b72selfTff7b72.Td2a8ff_out_messagesTb4b4b4: Te6edf3collectionsTff7b72.Td2a8ffOrderedDictTb4b4b4[

Tffa657intTb4b4b4, Te6edf3MQTTMessage

Tb4b4b4] Tff7b72= Te6edf3collectionsTff7b72.Td2a8ffOrderedDictTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_in_messagesTb4b4b4: Te6edf3collectionsTff7b72.Td2a8ffOrderedDictTb4b4b4[

Tffa657intTb4b4b4, Te6edf3MQTTMessage

Tb4b4b4] Tff7b72= Te6edf3collectionsTff7b72.Td2a8ffOrderedDictTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_max_inflight_messages Tff7b72= T79c0ff20

Tff7b72selfTff7b72.Td2a8ff_inflight_messages Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ff_max_queued_messages Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ff_connect_propertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_will_propertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_will Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_will_topic Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72selfTff7b72.Td2a8ff_will_payload Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72selfTff7b72.Td2a8ff_will_qos Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ff_will_retain Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_on_message_filtered Tff7b72= Te6edf3MQTTMatcherTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_host Tff7b72= Ta5d6ff"Ta5d6ff"

Tff7b72selfTff7b72.Td2a8ff_port Tff7b72= T79c0ff1883

Tff7b72selfTff7b72.Td2a8ff_bind_address Tff7b72= Ta5d6ff"Ta5d6ff"

Tff7b72selfTff7b72.Td2a8ff_bind_port Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ff_proxyTb4b4b4: Te6edf3Any Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ff_in_callback_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_callback_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffRLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_msgtime_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_out_message_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffRLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_in_message_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_reconnect_delay_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_mid_generate_mutex Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_threadTb4b4b4: Te6edf3threadingTff7b72.Td2a8ffThread Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_thread_terminate Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_ssl Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_ssl_contextTb4b4b4: Te6edf3sslTff7b72.Td2a8ffSSLContext Tff7b72| Tff7b72None Tff7b72= Tff7b72None

T8b949e# Only used when SSL context does not have check_hostname attribute

Tff7b72selfTff7b72.Td2a8ff_tls_insecure Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_loggerTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffLogger Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_registered_write Tff7b72= Tff7b72False

T8b949e# No default callbacks

Tff7b72selfTff7b72.Td2a8ff_on_logTb4b4b4: Te6edf3CallbackOnLog Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_pre_connectTb4b4b4: Te6edf3CallbackOnPreConnect Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_connectTb4b4b4: Te6edf3CallbackOnConnect Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_connect_failTb4b4b4: Te6edf3CallbackOnConnectFail Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_subscribeTb4b4b4: Te6edf3CallbackOnSubscribe Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_messageTb4b4b4: Te6edf3CallbackOnMessage Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_publishTb4b4b4: Te6edf3CallbackOnPublish Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_unsubscribeTb4b4b4: Te6edf3CallbackOnUnsubscribe Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_disconnectTb4b4b4: Te6edf3CallbackOnDisconnect Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_socket_openTb4b4b4: Te6edf3CallbackOnSocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_socket_closeTb4b4b4: Te6edf3CallbackOnSocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_socket_register_writeTb4b4b4: Te6edf3CallbackOnSocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_on_socket_unregister_writeTb4b4b4: Te6edf3CallbackOnSocket Tff7b72| Tff7b72None Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_websocket_path Tff7b72= Ta5d6ff"Ta5d6ff/mqttTa5d6ff"

Tff7b72selfTff7b72.Td2a8ff_websocket_extra_headersTb4b4b4: Te6edf3WebSocketHeaders Tff7b72| Tff7b72None Tff7b72= Tff7b72None

T8b949e# for clean_start == MQTT_CLEAN_START_FIRST_ONLY

Tff7b72selfTff7b72.Td2a8ff_mqttv5_first_connect Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffsuppress_exceptions Tff7b72= Tff7b72False T8b949e# For callbacks

Tff7b72def Tff7b72__del__Tb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_reset_socketsTb4b4b4(Tb4b4b4)

Tf0883e@property

Tff7b72def Td2a8ffhostTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

T8b949e"""

Host to connect to. If `connect()` hasn't been called yet, returns an empty string.

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_host

Tf0883e@hostTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffhostTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating host on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Tff7b72not Te6edf3valueTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInvalid host.Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_host Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffportTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

T8b949e"""

Broker TCP port to connect to.

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_port

Tf0883e@portTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffportTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating port on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72<Tff7b72= T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInvalid port number.Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_port Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffkeepaliveTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

T8b949e"""

Client keepalive interval (in seconds).

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_keepalive

Tf0883e@keepaliveTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffkeepaliveTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

T8b949e# The issue here is that the previous value of keepalive matter to possibly

T8b949e# sent ping packet.

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating keepalive on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72< T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffKeepalive must be >=0.Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_keepalive Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8fftransportTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3LiteralTb4b4b4[Ta5d6ff"Ta5d6fftcpTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwebsocketsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffunixTa5d6ff"Tb4b4b4]Tb4b4b4:

T8b949e"""

Transport method used for the connection ("tcp" or "websockets").

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_transport

Tf0883e@transportTff7b72.Td2a8ffsetter

Tff7b72def Td2a8fftransportTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Te6edf3LiteralTb4b4b4[Ta5d6ff"Ta5d6fftcpTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwebsocketsTa5d6ff"Tb4b4b4]Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating transport on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_transport Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffprotocolTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTProtocolVersionTb4b4b4:

T8b949e"""

Protocol version used (MQTT v3, MQTT v3.11, MQTTv5)

This property is read-only.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_protocol

Tf0883e@property

Tff7b72def Td2a8ffconnect_timeoutTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657floatTb4b4b4:

T8b949e"""

Connection establishment timeout in seconds.

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_connect_timeout

Tf0883e@connect_timeoutTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffconnect_timeoutTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657floatTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating connect_timeout on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72<Tff7b72= T79c0ff0.0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6fftimeout must be a positive numberTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_connect_timeout Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffusernameTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657str Tff7b72| Tff7b72NoneTb4b4b4:

T8b949e"""The username used to connect to the MQTT broker, or None if no username is used.

This property may not be changed if the connection is already open.

"""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_username Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return Tff7b72None

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_usernameTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tf0883e@usernameTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffusernameTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657str Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating username on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_username Tff7b72= Tff7b72None

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_username Tff7b72= Te6edf3valueTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tf0883e@property

Tff7b72def Td2a8ffpasswordTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657str Tff7b72| Tff7b72NoneTb4b4b4:

T8b949e"""The password used to connect to the MQTT broker, or None if no password is used.

This property may not be changed if the connection is already open.

"""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_password Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return Tff7b72None

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_passwordTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tf0883e@passwordTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffpasswordTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657str Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating password on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_password Tff7b72= Tff7b72None

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_password Tff7b72= Te6edf3valueTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tf0883e@property

Tff7b72def Td2a8ffmax_inflight_messagesTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

T8b949e"""

Maximum number of messages with QoS > 0 that can be partway through the network flow at once

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_max_inflight_messages

Tf0883e@max_inflight_messagesTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffmax_inflight_messagesTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

T8b949e# Not tested. Some doubt that everything is okay when max_inflight change between 0

T8b949e# and > 0 value because _update_inflight is skipped when _max_inflight_messages == 0

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating max_inflight_messages on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72< T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInvalid inflight.Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_max_inflight_messages Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffmax_queued_messagesTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

T8b949e"""

Maximum number of message in the outgoing message queue, 0 means unlimited

This property may not be changed if the connection is already open.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_max_queued_messages

Tf0883e@max_queued_messagesTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffmax_queued_messagesTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_connection_closedTb4b4b4(Tb4b4b4)Tb4b4b4:

T8b949e# Not tested.

Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffupdating max_queued_messages on established connection is not supportedTa5d6ff"Tb4b4b4)

Tff7b72if Te6edf3value Tff7b72< T79c0ff0Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInvalid queue size.Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_max_queued_messages Tff7b72= Te6edf3value

Tf0883e@property

Tff7b72def Td2a8ffwill_topicTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657str Tff7b72| Tff7b72NoneTb4b4b4:

T8b949e"""

The topic name a will message is sent to when disconnecting unexpectedly. None if a will shall not be sent.

This property is read-only. Use `will_set()` to change its value.

"""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_will_topic Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return Tff7b72None

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_will_topicTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tf0883e@property

Tff7b72def Td2a8ffwill_payloadTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytes Tff7b72| Tff7b72NoneTb4b4b4:

T8b949e"""

The payload for the will message that is sent when disconnecting unexpectedly. None if a will shall not be sent.

This property is read-only. Use `will_set()` to change its value.

"""

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_will_payload

Tf0883e@property

Tff7b72def Td2a8ffloggerTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Te6edf3loggingTff7b72.Td2a8ffLogger Tff7b72| Tff7b72NoneTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_logger

Tf0883e@loggerTff7b72.Td2a8ffsetter

Tff7b72def Td2a8ffloggerTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffLogger Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_logger Tff7b72= Te6edf3value

Tff7b72def Td2a8ff_sock_recvTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3bufsizeTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_sock Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ConnectionErrorTb4b4b4(Ta5d6ff"Ta5d6ffself._sock is NoneTa5d6ff"Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_sockTff7b72.Td2a8ffrecvTb4b4b4(Te6edf3bufsizeTb4b4b4)

Tff7b72except Te6edf3sslTff7b72.Td2a8ffSSLWantReadError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72raise Tf85149BlockingIOErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72except Te6edf3sslTff7b72.Td2a8ffSSLWantWriteError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_call_socket_register_writeTb4b4b4(Tb4b4b4)

Tff7b72raise Tf85149BlockingIOErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72except Tf85149AttributeError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_easy_logTb4b4b4(

Te6edf3MQTT_LOG_DEBUGTb4b4b4, Ta5d6ff"Ta5d6ffsocket was None: Tffd700%sTa5d6ff"Tb4b4b4, Te6edf3errTb4b4b4)

Tff7b72raise Tf85149ConnectionErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72def Td2a8ff_sock_sendTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3bufTb4b4b4: Tffa657bytesTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_sock Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ConnectionErrorTb4b4b4(Ta5d6ff"Ta5d6ffself._sock is NoneTa5d6ff"Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ff_sockTff7b72.Td2a8ffsendTb4b4b4(Te6edf3bufTb4b4b4)

Tff7b72except Te6edf3sslTff7b72.Td2a8ffSSLWantReadError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72raise Tf85149BlockingIOErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72except Te6edf3sslTff7b72.Td2a8ffSSLWantWriteError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_call_socket_register_writeTb4b4b4(Tb4b4b4)

Tff7b72raise Tf85149BlockingIOErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72except Tf85149BlockingIOError Tff7b72as Te6edf3errTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_call_socket_register_writeTb4b4b4(Tb4b4b4)

Tff7b72raise Tf85149BlockingIOErrorTb4b4b4(Tb4b4b4) Tff7b72from T7ee787err

Tff7b72def Td2a8ff_sock_closeTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Close the connection to the server."""

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_sockTb4b4b4:

Tff7b72return

Tff7b72tryTb4b4b4:

Te6edf3sock Tff7b72= Tff7b72selfTff7b72.Td2a8ff_sock

Tff7b72selfTff7b72.Td2a8ff_sock Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_call_socket_unregister_writeTb4b4b4(Te6edf3sockTb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_call_socket_closeTb4b4b4(Te6edf3sockTb4b4b4)

Tff7b72finallyTb4b4b4:

T8b949e# In case a callback fails, still close the socket to avoid leaking the file descriptor.

Te6edf3sockTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ff_reset_socketsTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sockpair_onlyTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Te6edf3sockpair_onlyTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_sock_closeTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_sockpairRTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_sockpairRTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_sockpairR Tff7b72= Tff7b72None

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_sockpairWTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_sockpairWTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_sockpairW Tff7b72= Tff7b72None

Tff7b72def Td2a8ffreinitialiseTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3client_idTb4b4b4: Tffa657str Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,

Te6edf3clean_sessionTb4b4b4: Tffa657bool Tff7b72= Tff7b72TrueTb4b4b4,

Te6edf3userdataTb4b4b4: Te6edf3Any Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_reset_socketsTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff__init__Tb4b4b4(Te6edf3client_idTb4b4b4, Te6edf3clean_sessionTb4b4b4, Te6edf3userdataTb4b4b4) T8b949e# type: ignore[misc]

Tff7b72def Td2a8ffws_set_optionsTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3pathTb4b4b4: Tffa657str Tff7b72= Ta5d6ff"Ta5d6ff/mqttTa5d6ff"Tb4b4b4,

Te6edf3headersTb4b4b4: Te6edf3WebSocketHeaders Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e""" Set the path and headers for a websocket connection

:param str path: a string starting with / which should be the endpoint of the

mqtt connection on the remote server

:param headers: can be either a dict or a callable object. If it is a dict then

the extra items in the dict are added to the websocket headers. If it is

a callable, then the default websocket headers are passed into this

function and the result is used as the new headers.

"""

Tff7b72selfTff7b72.Td2a8ff_websocket_path Tff7b72= Te6edf3path

Tff7b72if Te6edf3headers Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3headersTb4b4b4, Tffa657dictTb4b4b4) Tff7b72or Tffa657callableTb4b4b4(Te6edf3headersTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_websocket_extra_headers Tff7b72= Te6edf3headers

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff"Ta5d6ff'Ta5d6ffheadersTa5d6ff'Ta5d6ff option to ws_set_options has to be either a dictionary or callableTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8fftls_set_contextTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3contextTb4b4b4: Te6edf3sslTff7b72.Td2a8ffSSLContext Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Configure network encryption and authentication context. Enables SSL/TLS support.

:param context: an ssl.SSLContext object. By default this is given by

``ssl.create_default_context()``, if available.

Must be called before `connect()`, `connect_async()` or `connect_srv()`."""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_ssl_context Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffSSL/TLS has already been configured.Ta5d6ff'Tb4b4b4)

Tff7b72if Te6edf3context Tff7b72is Tff7b72NoneTb4b4b4:

Te6edf3context Tff7b72= Te6edf3sslTff7b72.Td2a8ffcreate_default_contextTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_ssl Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ff_ssl_context Tff7b72= Te6edf3context

T8b949e# Ensure _tls_insecure is consistent with check_hostname attribute

Tff7b72if Tffa657hasattrTb4b4b4(Te6edf3contextTb4b4b4, Ta5d6ff'Ta5d6ffcheck_hostnameTa5d6ff'Tb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_tls_insecure Tff7b72= Tff7b72not Te6edf3contextTff7b72.Td2a8ffcheck_hostname

Tff7b72def Td2a8fftls_setTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3ca_certsTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3certfileTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3keyfileTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3cert_reqsTb4b4b4: Te6edf3sslTff7b72.Td2a8ffVerifyMode Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3tls_versionTb4b4b4: Tffa657int Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3ciphersTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3keyfile_passwordTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3alpn_protocolsTb4b4b4: Tffa657listTb4b4b4[Tffa657strTb4b4b4] Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Configure network encryption and authentication options. Enables SSL/TLS support.

:param str ca_certs: a string path to the Certificate Authority certificate files

that are to be treated as trusted by this client. If this is the only

option given then the client will operate in a similar manner to a web

browser. That is to say it will require the broker to have a

certificate signed by the Certificate Authorities in ca_certs and will

communicate using TLS v1,2, but will not attempt any form of

authentication. This provides basic network encryption but may not be

sufficient depending on how the broker is configured.

By default, on Python 2.7.9+ or 3.4+, the default certification

authority of the system is used. On older Python version this parameter

is mandatory.

:param str certfile: PEM encoded client certificate filename. Used with

keyfile for client TLS based authentication. Support for this feature is

broker dependent. Note that if the files in encrypted and needs a password to

decrypt it, then this can be passed using the keyfile_password argument - you

should take precautions to ensure that your password is

not hard coded into your program by loading the password from a file

for example. If you do not provide keyfile_password, the password will

be requested to be typed in at a terminal window.

:param str keyfile: PEM encoded client private keys filename. Used with

certfile for client TLS based authentication. Support for this feature is

broker dependent. Note that if the files in encrypted and needs a password to

decrypt it, then this can be passed using the keyfile_password argument - you

should take precautions to ensure that your password is

not hard coded into your program by loading the password from a file

for example. If you do not provide keyfile_password, the password will

be requested to be typed in at a terminal window.

:param cert_reqs: the certificate requirements that the client imposes

on the broker to be changed. By default this is ssl.CERT_REQUIRED,

which means that the broker must provide a certificate. See the ssl

pydoc for more information on this parameter.

:param tls_version: the version of the SSL/TLS protocol used to be

specified. By default TLS v1.2 is used. Previous versions are allowed

but not recommended due to possible security problems.

:param str ciphers: encryption ciphers that are allowed

for this connection, or None to use the defaults. See the ssl pydoc for

more information.

Must be called before `connect()`, `connect_async()` or `connect_srv()`."""

Tff7b72if Te6edf3ssl Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffThis platform has no SSL/TLS.Ta5d6ff'Tb4b4b4)

Tff7b72if Tff7b72not Tffa657hasattrTb4b4b4(Te6edf3sslTb4b4b4, Ta5d6ff'Ta5d6ffSSLContextTa5d6ff'Tb4b4b4)Tb4b4b4:

T8b949e# Require Python version that has SSL context support in standard library

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff'Ta5d6ffPython 2.7.9 and 3.2 are the minimum supported versions for TLS.Ta5d6ff'Tb4b4b4)

Tff7b72if Te6edf3ca_certs Tff7b72is Tff7b72None Tff7b72and Tff7b72not Tffa657hasattrTb4b4b4(Te6edf3sslTff7b72.Td2a8ffSSLContextTb4b4b4, Ta5d6ff'Ta5d6ffload_default_certsTa5d6ff'Tb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff'Ta5d6ffca_certs must not be None.Ta5d6ff'Tb4b4b4)

T8b949e# Create SSLContext object

Tff7b72if Te6edf3tls_version Tff7b72is Tff7b72NoneTb4b4b4:

Te6edf3tls_version Tff7b72= Te6edf3sslTff7b72.Td2a8ffPROTOCOL_TLSv1_2

T8b949e# If the python version supports it, use highest TLS version automatically

Tff7b72if Tffa657hasattrTb4b4b4(Te6edf3sslTb4b4b4, Ta5d6ff"Ta5d6ffPROTOCOL_TLS_CLIENTTa5d6ff"Tb4b4b4)Tb4b4b4:

T8b949e# This also enables CERT_REQUIRED and check_hostname by default.

Te6edf3tls_version Tff7b72= Te6edf3sslTff7b72.Td2a8ffPROTOCOL_TLS_CLIENT

Tff7b72elif Tffa657hasattrTb4b4b4(Te6edf3sslTb4b4b4, Ta5d6ff"Ta5d6ffPROTOCOL_TLSTa5d6ff"Tb4b4b4)Tb4b4b4:

Te6edf3tls_version Tff7b72= Te6edf3sslTff7b72.Td2a8ffPROTOCOL_TLS

Te6edf3context Tff7b72= Te6edf3sslTff7b72.Td2a8ffSSLContextTb4b4b4(Te6edf3tls_versionTb4b4b4)

T8b949e# Configure context

Tff7b72if Te6edf3ciphers Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Te6edf3contextTff7b72.Td2a8ffset_ciphersTb4b4b4(Te6edf3ciphersTb4b4b4)

Tff7b72if Te6edf3certfile Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Te6edf3contextTff7b72.Td2a8ffload_cert_chainTb4b4b4(Te6edf3certfileTb4b4b4, Te6edf3keyfileTb4b4b4, Te6edf3keyfile_passwordTb4b4b4)

Tff7b72if Te6edf3cert_reqs Tff7b72== Te6edf3sslTff7b72.Td2a8ffCERT_NONE Tff7b72and Tffa657hasattrTb4b4b4(Te6edf3contextTb4b4b4, Ta5d6ff'Ta5d6ffcheck_hostnameTa5d6ff'Tb4b4b4)Tb4b4b4:

Te6edf3contextTff7b72.Td2a8ffcheck_hostname Tff7b72= Tff7b72False

Te6edf3contextTff7b72.Td2a8ffverify_mode Tff7b72= Te6edf3sslTff7b72.Td2a8ffCERT_REQUIRED Tff7b72if Te6edf3cert_reqs Tff7b72is Tff7b72None Tff7b72else Te6edf3cert_reqs

Tff7b72if Te6edf3ca_certs Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Te6edf3contextTff7b72.Td2a8ffload_verify_locationsTb4b4b4(Te6edf3ca_certsTb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3contextTff7b72.Td2a8ffload_default_certsTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3alpn_protocols Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tffa657getattrTb4b4b4(Te6edf3sslTb4b4b4, Ta5d6ff"Ta5d6ffHAS_ALPNTa5d6ff"Tb4b4b4, Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffSSL library has no support for ALPNTa5d6ff"Tb4b4b4)

Te6edf3contextTff7b72.Td2a8ffset_alpn_protocolsTb4b4b4(Te6edf3alpn_protocolsTb4b4b4)

Tff7b72selfTff7b72.Td2a8fftls_set_contextTb4b4b4(Te6edf3contextTb4b4b4)

Tff7b72if Te6edf3cert_reqs Tff7b72!= Te6edf3sslTff7b72.Td2a8ffCERT_NONETb4b4b4:

T8b949e# Default to secure, sets context.check_hostname attribute

T8b949e# if available

Tff7b72selfTff7b72.Td2a8fftls_insecure_setTb4b4b4(Tff7b72FalseTb4b4b4)

Tff7b72elseTb4b4b4:

T8b949e# But with ssl.CERT_NONE, we can not check_hostname

Tff7b72selfTff7b72.Td2a8fftls_insecure_setTb4b4b4(Tff7b72TrueTb4b4b4)

Tff7b72def Td2a8fftls_insecure_setTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3valueTb4b4b4: Tffa657boolTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Configure verification of the server hostname in the server certificate.

If value is set to true, it is impossible to guarantee that the host

you are connecting to is not impersonating your server. This can be

useful in initial server testing, but makes it possible for a malicious

third party to impersonate your server through DNS spoofing, for

example.

Do not use this function in a real system. Setting value to true means

there is no point using encryption.

Must be called before `connect()` and after either `tls_set()` or

`tls_set_context()`."""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_ssl_context Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff'Ta5d6ffMust configure SSL context before using tls_insecure_set.Ta5d6ff'Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_tls_insecure Tff7b72= Te6edf3value

T8b949e# Ensure check_hostname is consistent with _tls_insecure attribute

Tff7b72if Tffa657hasattrTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_ssl_contextTb4b4b4, Ta5d6ff'Ta5d6ffcheck_hostnameTa5d6ff'Tb4b4b4)Tb4b4b4:

T8b949e# Rely on SSLContext to check host name

T8b949e# If verify_mode is CERT_NONE then the host name will never be checked

Tff7b72selfTff7b72.Td2a8ff_ssl_contextTff7b72.Td2a8ffcheck_hostname Tff7b72= Tff7b72not Te6edf3value

Tff7b72def Td2a8ffproxy_setTb4b4b4(Tff7b72selfTb4b4b4, Tff7b72*Tff7b72*Te6edf3proxy_argsTb4b4b4: Te6edf3AnyTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Configure proxying of MQTT connection. Enables support for SOCKS or

HTTP proxies.

Proxying is done through the PySocks library. Brief descriptions of the

proxy_args parameters are below; see the PySocks docs for more info.

(Required)

:param proxy_type: One of {socks.HTTP, socks.SOCKS4, or socks.SOCKS5}

:param proxy_addr: IP address or DNS name of proxy server

(Optional)

:param proxy_port: (int) port number of the proxy server. If not provided,

the PySocks package default value will be utilized, which differs by proxy_type.

:param proxy_rdns: boolean indicating whether proxy lookup should be performed

remotely (True, default) or locally (False)

:param proxy_username: username for SOCKS5 proxy, or userid for SOCKS4 proxy

:param proxy_password: password for SOCKS5 proxy

Example::

mqttc.proxy_set(proxy_type=socks.HTTP, proxy_addr='1.2.3.4', proxy_port=4231)

"""

Tff7b72if Te6edf3socks Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffPySocks must be installed for proxy support.Ta5d6ff"Tb4b4b4)

Tff7b72elif Tff7b72not Tff7b72selfTff7b72.Td2a8ff_proxy_is_validTb4b4b4(Te6edf3proxy_argsTb4b4b4)Tb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffproxy_type and/or proxy_addr are invalid.Ta5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_proxy Tff7b72= Te6edf3proxy_args

Tff7b72def Td2a8ffenable_loggerTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3loggerTb4b4b4: Te6edf3loggingTff7b72.Td2a8ffLogger Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""

Enables a logger to send log messages to

:param logging.Logger logger: if specified, that ``logging.Logger`` object will be used, otherwise

one will be created automatically.

See `disable_logger` to undo this action.

"""

Tff7b72if Te6edf3logger Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_logger Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

T8b949e# Do not replace existing logger

Tff7b72return

Te6edf3logger Tff7b72= Te6edf3loggingTff7b72.Td2a8ffgetLoggerTb4b4b4(Tff7b72__name__Tb4b4b4)

Tff7b72selfTff7b72.Td2a8fflogger Tff7b72= Te6edf3logger

Tff7b72def Td2a8ffdisable_loggerTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""

Disable logging using standard python logging package. This has no effect on the `on_log` callback.

"""

Tff7b72selfTff7b72.Td2a8ff_logger Tff7b72= Tff7b72None

Tff7b72def Td2a8ffconnectTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3hostTb4b4b4: Tffa657strTb4b4b4,

Te6edf3portTb4b4b4: Tffa657int Tff7b72= T79c0ff1883Tb4b4b4,

Te6edf3keepaliveTb4b4b4: Tffa657int Tff7b72= T79c0ff60Tb4b4b4,

Te6edf3bind_addressTb4b4b4: Tffa657str Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,

Te6edf3bind_portTb4b4b4: Tffa657int Tff7b72= T79c0ff0Tb4b4b4,

Te6edf3clean_startTb4b4b4: Te6edf3CleanStartOption Tff7b72= Te6edf3MQTT_CLEAN_START_FIRST_ONLYTb4b4b4,

Te6edf3propertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTErrorCodeTb4b4b4:

T8b949e"""Connect to a remote broker. This is a blocking call that establishes

the underlying connection and transmits a CONNECT packet.

Note that the connection status will not be updated until a CONNACK is received and

processed (this requires a running network loop, see `loop_start`, `loop_forever`, `loop`...).

:param str host: the hostname or IP address of the remote broker.

:param int port: the network port of the server host to connect to. Defaults to

1883. Note that the default port for MQTT over SSL/TLS is 8883 so if you

are using `tls_set()` the port may need providing.

:param int keepalive: Maximum period in seconds between communications with the

broker. If no other messages are being exchanged, this controls the

rate at which the client will send ping messages to the broker.

:param bool clean_start: (MQTT v5.0 only) True, False or MQTT_CLEAN_START_FIRST_ONLY.

Sets the MQTT v5.0 clean_start flag always, never or on the first successful connect only,

respectively. MQTT session data (such as outstanding messages and subscriptions)

is cleared on successful connect when the clean_start flag is set.

For MQTT v3.1.1, the ``clean_session`` argument of `Client` should be used for similar

result.

:param Properties properties: (MQTT v5.0 only) the MQTT v5.0 properties to be sent in the

MQTT connect packet.

"""

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_protocol Tff7b72== Te6edf3MQTTv5Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_mqttv5_first_connect Tff7b72= Tff7b72True

Tff7b72elseTb4b4b4:

Tff7b72if Te6edf3clean_start Tff7b72!= Te6edf3MQTT_CLEAN_START_FIRST_ONLYTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffClean start only applies to MQTT V5Ta5d6ff"Tb4b4b4)

Tff7b72if Te6edf3propertiesTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffProperties only apply to MQTT V5Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffconnect_asyncTb4b4b4(Te6edf3hostTb4b4b4, Te6edf3portTb4b4b4, Te6edf3keepaliveTb4b4b4,

Te6edf3bind_addressTb4b4b4, Te6edf3bind_portTb4b4b4, Te6edf3clean_startTb4b4b4, Te6edf3propertiesTb4b4b4)

Tff7b72return Tff7b72selfTff7b72.Td2a8ffreconnectTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffconnect_srvTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3domainTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3keepaliveTb4b4b4: Tffa657int Tff7b72= T79c0ff60Tb4b4b4,

Te6edf3bind_addressTb4b4b4: Tffa657str Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,

Te6edf3bind_portTb4b4b4: Tffa657int Tff7b72= T79c0ff0Tb4b4b4,

Te6edf3clean_startTb4b4b4: Te6edf3CleanStartOption Tff7b72= Te6edf3MQTT_CLEAN_START_FIRST_ONLYTb4b4b4,

Te6edf3propertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Te6edf3MQTTErrorCodeTb4b4b4:

T8b949e"""Connect to a remote broker.

:param str domain: the DNS domain to search for SRV records; if None,

try to determine local domain name.

:param keepalive, bind_address, clean_start and properties: see `connect()`

"""

Tff7b72if Te6edf3HAVE_DNS Tff7b72is Tff7b72FalseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(

Ta5d6ff'Ta5d6ffNo DNS resolver library found, try Ta5d6ff"Ta5d6ffpip install dnspythonTa5d6ff"Ta5d6ff.Ta5d6ff'Tb4b4b4)

Tff7b72if Te6edf3domain Tff7b72is Tff7b72NoneTb4b4b4:

Te6edf3domain Tff7b72= Te6edf3socketTff7b72.Td2a8ffgetfqdnTb4b4b4(Tb4b4b4)

Te6edf3domain Tff7b72= Te6edf3domainTb4b4b4[Te6edf3domainTff7b72.Td2a8fffindTb4b4b4(Ta5d6ff'Ta5d6ff.Ta5d6ff'Tb4b4b4) Tff7b72+ T79c0ff1Tb4b4b4:Tb4b4b4]

Tff7b72tryTb4b4b4:

Te6edf3rr Tff7b72= Ta5d6fffTa5d6ff'Ta5d6ff_mqtt._tcp.Tffd700{Te6edf3domainTffd700}Ta5d6ff'

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_sslTb4b4b4:

T8b949e# IANA specifies secure-mqtt (not mqtts) for port 8883

Te6edf3rr Tff7b72= Ta5d6fffTa5d6ff'Ta5d6ff_secure-mqtt._tcp.Tffd700{Te6edf3domainTffd700}Ta5d6ff'

Te6edf3answers Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3answer Tff7b72in Te6edf3dnsTff7b72.Td2a8ffresolverTff7b72.Td2a8ffqueryTb4b4b4(Te6edf3rrTb4b4b4, Te6edf3dnsTff7b72.Td2a8ffrdatatypeTff7b72.Td2a8ffSRVTb4b4b4)Tb4b4b4:

Te6edf3addr Tff7b72= Te6edf3answerTff7b72.Td2a8fftargetTff7b72.Td2a8ffto_textTb4b4b4(Tb4b4b4)Tb4b4b4[Tb4b4b4:Tff7b72-T79c0ff1Tb4b4b4]

Te6edf3answersTff7b72.Td2a8ffappendTb4b4b4(

Tb4b4b4(Te6edf3addrTb4b4b4, Te6edf3answerTff7b72.Td2a8ffportTb4b4b4, Te6edf3answerTff7b72.Td2a8ffpriorityTb4b4b4, Te6edf3answerTff7b72.Td2a8ffweightTb4b4b4)Tb4b4b4)

Tff7b72except Tb4b4b4(Te6edf3dnsTff7b72.Td2a8ffresolverTff7b72.Td2a8ffNXDOMAINTb4b4b4, Te6edf3dnsTff7b72.Td2a8ffresolverTff7b72.Td2a8ffNoAnswerTb4b4b4, Te6edf3dnsTff7b72.Td2a8ffresolverTff7b72.Td2a8ffNoNameserversTb4b4b4) Tff7b72as Te6edf3errTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffNo answer/NXDOMAIN for SRV in Tffd700{Te6edf3domainTffd700}Ta5d6ff"Tb4b4b4) Tff7b72from T7ee787err

T8b949e# FIXME: doesn't account for weight

Tff7b72for Te6edf3answer Tff7b72in Te6edf3answersTb4b4b4:

Te6edf3hostTb4b4b4, Te6edf3portTb4b4b4, Te6edf3prioTb4b4b4, Te6edf3weight Tff7b72= Te6edf3answer

Tff7b72tryTb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffconnectTb4b4b4(Te6edf3hostTb4b4b4, Te6edf3portTb4b4b4, Te6edf3keepaliveTb4b4b4, Te6edf3bind_addressTb4b4b4, Te6edf3bind_portTb4b4b4, Te6edf3clean_startTb4b4b4, Te6edf3propertiesTb4b4b4)

Tff7b72except Tf85149ExceptionTb4b4b4: T8b949e# noqa: S110

Tff7b72pass

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffNo SRV hosts respondedTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffconnect_asyncTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3hostTb4b4b4: Tffa657strTb4b4b4,

Te6edf3portTb4b4b4: Tffa657int Tff7b72= T79c0ff1883Tb4b4b4,

Te6edf3keepaliveTb4b4b4: Tffa657int Tff7b72= T79c0ff60Tb4b4b4,

Te6edf3bind_addressTb4b4b4: Tffa657str Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,

Te6edf3bind_portTb4b4b4: Tffa657int Tff7b72= T79c0ff0Tb4b4b4,

Te6edf3clean_startTb4b4b4: Te6edf3CleanStartOption Tff7b72= Te6edf3MQTT_CLEAN_START_FIRST_ONLYTb4b4b4,

Te6edf3propertiesTb4b4b4: Te6edf3Properties Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

T8b949e"""Connect to a remote broker asynchronously. This is a non-blocking

connect call that can be used with `loop_start()` to provide very quick

start.

Any already established connection will be terminated immediately.